package study.core.rdd

import org.apache.spark.{SparkConf, SparkContext}

/**
 * 创建RDD的方式一
 * 从集合（内存）中创建 RDD
 *
 * @author zh
 * @date 2021/5/15 08:37
 */
object Create01 {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("createRdd")
    val context = new SparkContext(sparkConf)

    // 准备集合
    val list = List(1,2,3,4)
    // 创建RDD
    val rdd = context.parallelize(list)
    // 该方法内部也是直接调用的parallelize(seq, numSlices)
    context.makeRDD(list)
    rdd.collect().foreach(println)

    context.stop()
  }
}
